package zero.tech.redis.topic;

import zero.tech.core.util.EngineLogUtil;

public abstract class TopicProcess extends RedisTopicProcess {
	public String message;

	@Override
	public void init(Object... objs) {
		this.message = (String) objs[0];
	}

	@Override
	public void run() {
		try {
			this.process(message);
		} catch (Exception e) {
			EngineLogUtil.traceFull(e);
		}
	}
}
